package com.solver.demo.rscoket.v2.server;

import com.solver.demo.rscoket.v2.api.ChannelMessage;
import org.springframework.stereotype.Service;
import reactor.core.publisher.Mono;

/**
 * @author：fangn
 * @since：2025/4/2
 */
@Service
public class DefaultMessageProcessor implements MessageProcessor {
    @Override
    public Mono<String> process(ChannelMessage message) {
        // 具体业务逻辑实现
        return Mono.just("Default MessageProcessor: " + message.getContent());
    }
}